package com.dify.service;



import com.dify.domain.resp.StopResponse;
import com.dify.domain.resp.StreamResponse;
import reactor.core.publisher.Flux;

public interface DifyService {



    /**
     * 流式调用dify.
     *
     * @param query  查询文本
     * @param userId 用户id
     * @param apiKey apiKey 通过 apiKey 获取权限并区分不同的 dify 应用
     * @return Flux 响应流
     */
     Flux<StreamResponse> streamingMessage(String conversationId, String upContext, String query, String userId, String apiKey) ;






    /**
     * 停止响应
     */
    StopResponse stopMessage(String taskId, String userId, String apiKey);
}